565c57e433d9adef085fc227288b052b2fa0e1cb,cdap-hbase-compat-0.98/src/main/java/co/cask/cdap/data2/increment/hbase98/IncrementHandler.java,IncrementHandler,preCompact,#ObserverContext#Store#InternalScanner#ScanType#,175
Before Change
public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store,
InternalScanner scanner, ScanType scanType) throws IOException {
TransactionSnapshot snapshot = cache.getLatestState();
if (snapshot != null) {
return new IncrementSummingScanner(region, BATCH_UNLIMITED, scanner, snapshot.getVisibilityUpperBound());
}
return new IncrementSummingScanner(region, BATCH_UNLIMITED, scanner);
}
@Override
After Change
public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store,
InternalScanner scanner, ScanType scanType) throws IOException {
TransactionSnapshot snapshot = cache.getLatestState();
return new IncrementSummingScanner(region, BATCH_UNLIMITED, scanner, scanType,
snapshot != null ? snapshot.getVisibilityUpperBound() : 0);
}
@Override